package com.hjc.demo.flink.kafka.consumer;

import java.util.Objects;

public class CommonProperties {

    static String brokerList = "1.15.51.162:9092";

    static String TOPIC = "flink_kafka";

    static String GROUP_ID = "consumer-group";

    static {
        String brokerList = System.getProperty("broker-list");
        if (Objects.nonNull(brokerList)) {
            CommonProperties.brokerList = brokerList;
        }
    }
}
